package cn.edu.njpi;

import cn.edu.njpi.trip.TripDriver;

import java.io.IOException;

/**
 * @author 朱宗辉
 * @version V1.0
 * @Package cn.edu.njpi
 * @date 2021/11/17 下午8:24
 */
public class Main {
    public static void main(String[] args) throws IOException, InterruptedException, ClassNotFoundException {
        // 这个为数数字的wordcount，这个为使用hadoop集群分析方式
        /*{
            // 要分析的文件路径
            String input = "/Users/zhuzonghui/test";
            // 分析完成导出文件的路径,此路径必须不存在
            String output = "/Users/zhuzonghui/out";
            WordCountUtils.wordcount(input, output);
        }*/

        // 这个为分析红黄绿码，并分类输出的，为本地分析模式
        // 要分析的数据地址
        args[0] = "/Users/zhuzonghui/Downloads/hadoop/实训数据/江苏省用户行程信息.csv";
        // 输出的文件地址，此文件夹不能存在
        args[1] = "/Users/zhuzonghui/Downloads/hadoop/实训数据/out";
        TripDriver.main(args);

    }
}
